package cn.itcast.dmp.process

import org.apache.spark.internal.Logging
import org.apache.spark.sql.DataFrame

//数据处理接口，其中函数processData对数据集DataFrame进行处理转换，
// 对DataFrame类型数据进行处理
trait Processor extends Logging{
  def processData(dataframe: DataFrame): DataFrame
}
